const Rx = require('rxjs')

const observable = new Rx.Observable(function (observer) {
	const id = setInterval(() => {
		console.log(id)
		observer.next('hi')
	}, 1e3)
	return () => {
		clearInterval(id)
	}
})
const unsubscribeHandle = observable.subscribe(function(x) {
	console.log('x', x)
})
setTimeout(() => {
	unsubscribeHandle.unsubscribe()
}, 5e3);

// observable.subscribe(function(x) {
// 	console.log('y', x)
// })
// Rx并不会存放订阅函数

// setTimeout(() => {
// 	observable.subscribe(function(x) {
// 		console.log('z', x)
// 	})
// }, 5e3);